<?php

class mysqldb {
	private $content;
	private $p;
	private $pm;
	public $m;
	private $row;
	public $contentid;
	public $insert_comment;
	public $insert_comment_one;
	public $comid;
	public $resm;

	public static $mConnect;	// Хранит результат соединения с базой данных
	public static $mSelectDB;	// Хранит результат выбора базы данных
	
	// Метод создает соединение с базой данных
	public static function Connect($host, $user, $pass, $name)
	{
		// Пробуем создать соединение с базой данных
		self::$mConnect = mysql_connect($host, $user, $pass);
	
		// Если подключение не прошло, вывести сообщение об ошибке..
		if(!self::$mConnect)
		{
			echo "<p><b>К сожалению, не удалось подключиться к серверу MySQL</b></p>";
			exit();
			return false;
		}
	
		// Пробуем выбрать базу данных
		self::$mSelectDB = mysql_select_db($name, self::$mConnect);
	
		// Если база данных не выбрана, вывести сообщение об ошибке..
		if(!self::$mSelectDB)
		{
			echo "<p><b>".mysql_error()."</b></p>";
			exit();
			return false;
		}
	
		// Возвращаем результат
		return self::$mConnect;
	}
	
	// Метод закрывает соединение с базой данных
	public static function Close()
	{
		// Возвращает результат
		return mysql_close(self::$mConnect);
	}
	
	function mysql_content() {
	
    $content = array();

	$resm = mysql_query("SELECT * FROM gb_messages ORDER BY id DESC;");
	$resm_count = mysql_query("SELECT COUNT(*) FROM gb_messages ORDER BY id DESC;");

	while (($row = mysql_fetch_assoc($resm)) !== false) {
	$content[] = $row; }
	
	while (($row_count = mysql_fetch_assoc($resm_count)) !== false) {
	$content_count[] = $row_count; }
	
	// $pm - содержит количество строк
	$pm=$content_count[0]['COUNT(*)'];
	
		for ($i=0; $i < $pm; $i++) {
			
		echo '<div class="msg"> <p class="leftstr">';
		print_r($content[$i]['name']);
		echo '</p> <p class="rightstr">';
		print_r($content[$i]['time']);
		echo '</p><div style="clear: left"></div><hr>';
		print_r($content[$i]['message']);
		echo '<br><hr>
		<p class="leftstr"><a href="kom_and_red.php?comid='; echo ($content[$i]['id']);
		echo '">Комментировать</a></p>
		<p class="rightstr"><a href="kom_and_red.php?redid='; echo ($content[$i]['id']);
		echo '">Редактировать</a> / <a href="index.php?delid='; echo ($content[$i]['id']);
		echo '">Удалить</a></p><div style="clear: left"></div></div><br>';

		$id_com=$content[$i]['id'];
		$id_count=$content[$i]['id'];

		$com_count= array();
		$sql_count = mysql_query("SELECT COUNT(*) FROM gb_comments WHERE id=".$id_count.";");
		while (($conv=mysql_fetch_assoc($sql_count)) !== false) {
		$com_count[] = $conv; }
		$p=$com_count[0]['COUNT(*)'];
		
		$insert_comment = array();
		$sql = mysql_query("SELECT * FROM gb_comments WHERE id=".$id_com." ORDER BY time");
		while (($conv_c=mysql_fetch_assoc($sql)) !== false) {
		$insert_comment[] = $conv_c; }
		
			for ($d=0; $d < $p; $d++) {
					if (! isset ($insert_comment[$d])) break; 
					echo '<div class="com"><p class="leftstr">';
					print_r($insert_comment[$d]['name']);
					echo '</p><p class="rightstr">';
					print_r($insert_comment[$d]['time']);
					echo '&nbsp;&nbsp;<a href="index.php?delid_com='; 
					echo ($insert_comment[$d]['commentid']);
					echo '">Удалить</a></p><div style="clear: left"></div><hr>';
					print_r($insert_comment[$d]['comment']);
					echo '</div><br>';
				}
		}
	} /*function */
	
	function mysql_content_com () {

		/* function mysql_contentid() */
		
			$this -> m = "Введите комментарий";
			$resm = mysql_query("SELECT * FROM `gb_messages` WHERE id = '".$_GET['comid']."'");
		
			while (($row=mysql_fetch_assoc($resm)) !== false) {
				$contentid[] = $row;}
		
				echo '<div class="msg"> <p class="leftstr">';
				print_r($contentid[0]['name']);
				echo '</p> <p class="rightstr">';
				print_r($contentid[0]['time']);
				echo '</p><div style="clear: left"></div><hr>';
				print_r($contentid[0]['message']);
				echo '</div>';

		/* function massiv_com */
				
				$insert_comment_one = array();
				$sql = mysql_query("SELECT * FROM gb_comments WHERE id=".$_GET['comid']." ORDER BY time");
				while (($conv_c=mysql_fetch_assoc($sql)) !== false) {
					$insert_comment_one[] = $conv_c; }
		
		/* function kol_com */
					$com_count= array();
					$sql_count = mysql_query("SELECT COUNT(*) FROM gb_comments WHERE id=".$_GET['comid'].";");
					while (($conv=mysql_fetch_assoc($sql_count)) !== false) {
						$com_count[] = $conv; }
					
					$p=$com_count[0]['COUNT(*)'];
					
					for ($d=0; $d < $p; $d++) {
						echo '<div class="com"><p class="leftstr">';
						print_r($insert_comment_one[$d]['name']);
						echo '</p><p class="rightstr">';
						print_r($insert_comment_one[$d]['time']);
						echo '&nbsp;&nbsp;<a href="index.php?delid_com=';
						echo ($insert_comment_one[$d]['commentid']);
						echo '">Удалить</a></p><div style="clear: left"></div><hr>';
						print_r($insert_comment_one[$d]['comment']);
						echo '</div><br>';
					}

					// Отправка комментария в базу
					if ( ! isset( $_POST['comment'] ) )
						$m = "Введите комментарий";
					elseif ( $_POST['comment'] == "" )
					$m = "Пустое сообщение";
					else
						if ( $_POST['namecom'] == "" )
						$m = "Пустое имя";
					else {
						$sql = "INSERT INTO `gb_comments` SET
						`name` = '".$_POST['namecom']."',
						`comment` = '".$_POST['comment']."',
						`time` = UTC_TIMESTAMP(),
						`id` = '".$_GET['comid']."';";
						$res = mysql_query($sql);
						echo'<META HTTP-EQUIV=Refresh Content="0;URL=create.php?s=Сообщение опубликовано">';
						return $_GET['comid'];
					}
	
						
	} /*function mysql_content_com */

	function mysql_content_com_edit (){
		/* Изменение комментария в базе */
		
		if (! isset($_POST['comment']))
			$m = "Введите сообщение";
		elseif ( $_POST['comment'] == "" )
			$m = "Пустое сообщение";
		else {
			$sql = "UPDATE `gb_messages` SET `message` = '".$_POST['comment']."' WHERE `id` = '".$_GET['redid']."';";
			$res = mysql_query($sql);
			echo'<META HTTP-EQUIV=Refresh Content="0;URL=create.php?s=Сообщение опубликовано">';
		}
		
	} /* function mysql_content_com_edit */
	
	function mysql_content_red () {
		
		$m = "Редактирование сообщения";
		$resm = mysql_query("SELECT * FROM  `gb_messages` WHERE id =  '".$_GET['redid']."'");
		while (($row=mysql_fetch_assoc($resm)) !== false) {
			$contentid[] = $row;
		}
		print_r($contentid[0]['message']);
	}
	
	function mysql_post () {
		$res = mysql_query("INSERT INTO `gb_messages` SET `name` = '".$_POST['name']."', `message` = '".$_POST['message']."', `time` = UTC_TIMESTAMP();");
	}
	
	function mysql_del () {
		$res = mysql_query("DELETE FROM gb_messages WHERE id='".$_GET['delid']."'");
	}
	
	function mysql_del_com () {
		$res = mysql_query("DELETE FROM gb_comments WHERE commentid='".$_GET['delid_com']."'");
	}
	
} /*class*/


class mysql_pdo {
	
	private $content_PDO;
	private $p_PDO;
	private $pm_PDO;
	public $m;
	private $row_PDO;
	public $contentid_PDO;
	public $insert_comment_PDO;
	public $insert_comment_one_PDO;
	public $comid_PDO;
	public $resm_PDO;
	public static $bdh;
	
	public function connect (){
		try {
			$this->bdh = new PDO('mysql:host=localhost;dbname=gb;charset=utf8', 'root', 'admin');
		}
		catch (Exception $e) {
			echo $e->getMessage();
		}	
		
		
	} /*function connect*/
	
	public function mysql_content () {
		
		foreach($this->bdh->query('SELECT * FROM gb_messages ORDER BY id DESC') as $row){
			
			echo '<div class="msg"> <p class="leftstr">';
			print_r($row['name']);
			echo '</p> <p class="rightstr">';
			print_r($row['time']);
			echo '</p><div style="clear: left"></div><hr>';
			print_r($row['message']);
			echo '<br><hr>
			<p class="leftstr"><a href="kom_and_red.php?comid='; echo ($row['id']);
			echo '">Комментировать</a></p>
			<p class="rightstr"><a href="kom_and_red.php?redid='; echo ($row['id']);
			echo '">Редактировать</a> / <a href="index.php?delid='; echo ($row['id']);
			echo '">Удалить</a></p><div style="clear: left"></div></div><br>';
		
			$id_com = $row ['id'];
			
				foreach($this->bdh->query("SELECT * FROM gb_comments WHERE id=".$id_com." ORDER BY time") as $row_com){
				
					echo '<div class="com"><p class="leftstr">';
					print_r($row_com['name']);
					echo '</p><p class="rightstr">';
					print_r($row_com['time']);
					echo '&nbsp;&nbsp;<a href="index.php?delid_com=';
					echo ($row_com['commentid']);
					echo '">Удалить</a></p><div style="clear: left"></div><hr>';
					print_r($row_com['comment']);
					echo '</div><br>';
				}
		}
	}/* function */

	public function mysql_post () {
		$this->bdh->query("INSERT INTO `gb_messages` SET `name` = ".$_POST['name'].", `message` = ".$_POST['message'].", `time` = UTC_TIMESTAMP();");
	}
	
	public function mysql_del () {
		$this->bdh->query("DELETE FROM `gb_messages` WHERE `id` = '".$_GET['delid']."';");
	}
	
	public function mysql_del_com () {
		$this->bdh->query("DELETE FROM `gb_comments` WHERE `commentid`='".$_GET['delid_com']."';");
	}
	
	public function mysql_content_com () {
		
		foreach($this->bdh->query("SELECT * FROM `gb_messages` WHERE id = ".$_GET['comid'].";") as $row) {
			
			echo '<div class="msg"> <p class="leftstr">';
			print_r($row['name']);
			echo '</p> <p class="rightstr">';
			print_r($row['time']);
			echo '</p><div style="clear: left"></div><hr>';
			print_r($row['message']);
			echo '</div>';
			
			foreach($this->bdh->query("SELECT * FROM gb_comments WHERE id=".$_GET['comid']." ORDER BY time") as $row_com){
				echo '<div class="com"><p class="leftstr">';
				print_r($row_com['name']);
				echo '</p><p class="rightstr">';
				print_r($row_com['time']);
				echo '&nbsp;&nbsp;<a href="index.php?delid_com=';
				echo ($row_com['commentid']);
				echo '">Удалить</a></p><div style="clear: left"></div><hr>';
				print_r($row_com['comment']);
				echo '</div><br>';
			}
		}
		
		if ( ! isset( $_POST['comment'] ) )
			$m = "Введите комментарий";
		elseif ( $_POST['comment'] == "" )
			$m = "Пустое сообщение";
		else
			if ( $_POST['namecom'] == "" )
			$m = "Пустое имя";
		else {
			$this->bdh->query("INSERT INTO `gb_comments` SET `name` = '".$_POST['namecom']."', `comment` = '".$_POST['comment']."', `time` = UTC_TIMESTAMP(), `id` = '".$_GET['comid']."';");
			echo'<META HTTP-EQUIV=Refresh Content="0;URL=create.php?s=Сообщение опубликовано">';
			return $_GET['comid'];
		}
	} /* function */
	
	public function mysql_content_com_edit () {
		
		if (! isset($_POST['comment']))
			$this->m = "Введите сообщение";
		elseif ( $_POST['comment'] == "" )
			$this->m = "Пустое сообщение";
		else {
			$this->bdh->query("UPDATE `gb_messages` SET `message` = '".$_POST['comment']."' WHERE `id` = '".$_GET['redid']."';");
			echo'<META HTTP-EQUIV=Refresh Content="0;URL=create.php?s=Сообщение опубликовано">';
		}
		
	} /*function*/
	
	public function mysql_content_red () {
		
		$this->m = "Редактирование сообщения";
		foreach($this->bdh->query("SELECT * FROM `gb_messages` WHERE id = '".$_GET['redid']."'") as $rows){
			print_r($rows['message']); }
		
	} /* function */
	

	
} /*class*/

//$object = new mysql_pdo();

$object = new mysqldb();

class mysql_export_import {
	
	public function export () {
		
		$csv_file =''; // создаем переменную, в которую записываем строки
		$query = "SELECT * FROM gb_messages";
		$result = mysql_query($query);
		if ($result)
		
		{
			while ($row = mysql_fetch_assoc($result))
			{
				$csv_file .= '"'.$row["id"].'","'.$row["name"].'","'.$row["message"].'","'.$row["time"].'"'."\r\n";
				// в качестве начала и конца полей " (двойные кавычки)
				// в качестве разделителей полей , (запятая)
				//   \r\n - это перенос строки
			}
		}
		
		$file_name = 'export.csv'; // название файла
		$file = fopen($file_name,"w"); // открываем файл для записи, если его нет, то создаем его в текущей папке, где расположен скрипт
		fwrite($file,trim($csv_file)); // записываем в файл строки
		fclose($file); // закрываем файл
	}
	
	$csv_file =''; // создаем переменную, в которую записываем строки
	$query = "SELECT * FROM gb_comments";
	$result = mysql_query($query);
	if ($result)
	
	{
		while ($row = mysql_fetch_assoc($result))
		{
			$csv_file .= '"'.$row["commentid"].'","'.$row["name"].'","'.$row["comment"].'","'.$row["time"].'","'.$row["id"].'"'."\r\n";
			// в качестве начала и конца полей " (двойные кавычки)
			// в качестве разделителей полей , (запятая)
			//   \r\n - это перенос строки
		}
	}
	
	$file_name = 'export_c.csv'; // название файла
	$file = fopen($file_name,"w"); // открываем файл для записи, если его нет, то создаем его в текущей папке, где расположен скрипт
	fwrite($file,trim($csv_file)); // записываем в файл строки
	fclose($file); // закрываем файл
	}
	
	public function import () {
		

		$result = mysql_query('LOAD DATA INFILE \'/www/gb.local/www/export.csv\' REPLACE INTO TABLE `gb_messages`
FIELDS TERMINATED BY \',\'
ENCLOSED BY \'"\'
LINES TERMINATED BY \'\n\' ');
		
$result = mysql_query('LOAD DATA INFILE \'/www/gb.local/www/export_c.csv\' REPLACE INTO TABLE `gb_comments`
FIELDS TERMINATED BY \',\'
ENCLOSED BY \'"\'
LINES TERMINATED BY \'\n\' ');		
		
	}
	
}




